type google.golang.org/grpc/internal/transport.http2Server
33 uses
google.golang.org/grpc/internal/transport (current package)
http2_server.go#L68: type http2Server struct {
http2_server.go#L247: t := &http2Server{
http2_server.go#L350: func (t *http2Server) operateHeaders(frame *http2.MetaHeadersFrame, handle func(*Stream), traceCtx func(context.Context, string) context.Context) error {
http2_server.go#L627: func (t *http2Server) HandleStreams(handle func(*Stream), traceCtx func(context.Context, string) context.Context) {
http2_server.go#L686: func (t *http2Server) getStream(f http2.Frame) (*Stream, bool) {
http2_server.go#L704: func (t *http2Server) adjustWindow(s *Stream, n uint32) {
http2_server.go#L714: func (t *http2Server) updateWindow(s *Stream, n uint32) {
http2_server.go#L725: func (t *http2Server) updateFlowControl(n uint32) {
http2_server.go#L747: func (t *http2Server) handleData(f *http2.DataFrame) {
http2_server.go#L814: func (t *http2Server) handleRSTStream(f *http2.RSTStreamFrame) {
http2_server.go#L829: func (t *http2Server) handleSettings(f *http2.SettingsFrame) {
http2_server.go#L862: func (t *http2Server) handlePing(f *http2.PingFrame) {
http2_server.go#L911: func (t *http2Server) handleWindowUpdate(f *http2.WindowUpdateFrame) {
http2_server.go#L931: func (t *http2Server) checkForHeaderListSize(it interface{}) bool {
http2_server.go#L948: func (t *http2Server) streamContextErr(s *Stream) error {
http2_server.go#L958: func (t *http2Server) WriteHeader(s *Stream, md metadata.MD) error {
http2_server.go#L982: func (t *http2Server) setResetPingStrikes() {
http2_server.go#L986: func (t *http2Server) writeHeaderLocked(s *Stream) error {
http2_server.go#L1025: func (t *http2Server) WriteStatus(s *Stream, st *status.Status) error {
http2_server.go#L1091: func (t *http2Server) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
http2_server.go#L1120: func (t *http2Server) keepalive() {
http2_server.go#L1214: func (t *http2Server) Close(err error) {
http2_server.go#L1244: func (t *http2Server) deleteStream(s *Stream, eosReceived bool) {
http2_server.go#L1265: func (t *http2Server) finishStream(s *Stream, rst bool, rstCode http2.ErrCode, hdr *headerFrame, eosReceived bool) {
http2_server.go#L1289: func (t *http2Server) closeStream(s *Stream, rst bool, rstCode http2.ErrCode, eosReceived bool) {
http2_server.go#L1306: func (t *http2Server) RemoteAddr() net.Addr {
http2_server.go#L1310: func (t *http2Server) Drain() {
http2_server.go#L1324: func (t *http2Server) outgoingGoAwayHandler(g *goAway) (bool, error) {
http2_server.go#L1382: func (t *http2Server) ChannelzMetric() *channelz.SocketInternalMetric {
http2_server.go#L1406: func (t *http2Server) IncrMsgSent() {
http2_server.go#L1411: func (t *http2Server) IncrMsgRecv() {
http2_server.go#L1416: func (t *http2Server) getOutFlowWindow() int64 {
http2_server.go#L1431: func (t *http2Server) getPeer() *peer.Peer {